package com.sumbo.config.reader;

import java.util.Map;
import java.util.Properties;

/**
 * \* User: MeiZhongHao
 * \* Date: 2019-06-10
 * \* Time: 16:59
 * \* Description: 输入工厂
 * \
 */
public class ReaderFactory {

    public static void init() {
        // 初始化 kafkaReader
        Map<String, Properties> kafkaReaderConfig = ReaderConfig.getKafkaConfig();
        KafkaReader.instance.init(kafkaReaderConfig);
        KafkaReader.instance.open();
        // ...
        Map<String, Properties> rocketMqConfig = ReaderConfig.getRocketMqConfig();
        RocketMqReader.instance.init(rocketMqConfig);
        RocketMqReader.instance.open();

        Map<String, Properties> httpConfig = ReaderConfig.getHttpConfig();
    }
}